
package com.jf.cloud.search.listener;

import cn.throwx.canal.gule.model.CanalBinLogEvent;
import cn.throwx.canal.gule.support.processor.BaseCanalBinlogEventProcessor;
import cn.throwx.canal.gule.support.processor.ExceptionHandler;
import com.jf.cloud.common.exception.LuckException;

/**
 * @author zz
 * @date 2021/4/7
 */
public class BaseCanalBinlogEventThrowExceptionProcessor<T> extends BaseCanalBinlogEventProcessor<T> {

    @Override
    protected ExceptionHandler exceptionHandler() {
        return (CanalBinLogEvent event, Throwable throwable) -> {
            throw new LuckException("创建索引异常",throwable);
        };
    }
}
